package a14waitandnotify;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: 86131
 * Date: 2024-04-17
 * Time: 17:33
 */
public class ThreadDemo {
    public static void main(String[] args) {
        /*
        * 需求: 利用阻塞队列完成后生产者和消费者(等待唤醒机制)的代码
        * 细节:
        *      生产者和消费者必须使用同一个阻塞队列
        * */

        //1.创建阻塞队列的对象
        ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(1);  //指定上限

        //2. 创建线程的对象,并把阻塞队列传递过去
        Cook c = new Cook(queue);
        Foodie f = new Foodie(queue);

        c.start();
        f.start();
    }
}
